package com.nami.ucenter.domain.port.publisher;


import com.nami.ucenter.domain.port.publisher.request.DownModeConfig;
import com.nami.ucenter.domain.port.publisher.request.DownMsgBatchReq;
import com.nami.ucenter.domain.port.publisher.request.DownMsgRequest;

public interface DomainEventPublisher {
    boolean publish(String topic, String tag, byte[] msg);
    boolean publish(String topic, String tag, String msg);
    boolean flushOne(DownMsgRequest request, DownModeConfig config) throws Exception;
    boolean flushMore(DownMsgBatchReq req, DownModeConfig config) throws Exception;
}
